python 连接并操作postgreSQL

2023-03-10 06:12| 来源: 网络整理| 查看: 265

使用Python中的psycopg2库来连接PostgreSQL并执行SQL语句

import psycopg2 # 连接到PostgreSQL数据库 conn = psycopg2.connect( host="your_host", database="your_database", user="your_username", password="your_password" ) # 创建一个游标对象 cur = conn.cursor() # 执行SQL查询 cur.execute("SELECT * FROM your_table") # 获取查询结果 rows = cur.fetchall() # 输出结果 for row in rows: print(row) # 关闭游标和数据库连接 cur.close() conn.close()

使用psycopg2库来连接到PostgreSQL数据库。然后，我们创建一个游标对象并使用execute()方法执行SQL查询。最后，我们使用fetchall()方法获取查询结果并使用一个简单的循环打印每一行。最后，我们关闭游标和数据库连接。

连接postgreSQL执行sql,并输出结果

将连接到 PostgreSQL 数据库的代码封装在一个 def 函数中，以便更方便地复用和调用。

import psycopg2 def connect_to_postgresql(): # 连接到 PostgreSQL 数据库 conn = psycopg2.connect( host="your_host", database="your_database", user="your_username", password="your_password" ) return conn def execute_sql_query(query): # 连接到 PostgreSQL 数据库 conn = connect_to_postgresql() # 创建一个游标对象 cur = conn.cursor() # 执行 SQL 查询 cur.execute(query) # 获取查询结果 rows = cur.fetchall() # 关闭游标和数据库连接 cur.close() conn.close() # 返回查询结果 return rows

我们定义了两个函数： connect_to_postgresql() 和 execute_sql_query(query)。

connect_to_postgresql() 函数用于连接到 PostgreSQL 数据库，并返回一个数据库连接对象 conn。

execute_sql_query(query) 函数接受一个 SQL 查询语句 query 作为参数，调用 connect_to_postgresql() 函数连接到数据库，创建一个游标对象 cur，执行查询语句，并使用 fetchall() 方法获取查询结果。最后，函数关闭游标和数据库连接，并返回查询结果。

使用以下方式调用 execute_sql_query(query) 函数：

# 执行查询并获取结果 query = "SELECT * FROM your_table" result = execute_sql_query(query) # 输出结果 for row in result: print(row)

【本文地址】

公司简介

联系我们